package com.github.codemperor.core.logger.test.mr.wordcount;

import com.github.codemperor.core.logger.compute.Context;
import com.github.codemperor.core.logger.compute.IReducerStreamingFunction;

import java.util.List;

public class WordCountReducer implements IReducerStreamingFunction {
    @Override
    public void reducing(Object k, List<Object> values, Context context) {
        context.reduce(k, values.size());
    }
}
